package com.allwe.client.group;

import com.allwe.client.commit.AsyncCommitBaseConsumer;
import com.allwe.client.singleGroup.SingleGroupBaseConsumer;
import lombok.extern.slf4j.Slf4j;

/**
 * kafka消费者启动器
 *
 * @Author: AllWe
 * @Date: 2024/09/24/17:57
 */
@Slf4j
public class GroupConsumer_2 {
    public static void main(String[] args) {
        AsyncCommitBaseConsumer asyncCommitBaseConsumer = new AsyncCommitBaseConsumer("allwe04", "topic_5");
        asyncCommitBaseConsumer.poll();
    }
}
